import os


root_path = os.path.join(os.path.dirname(__file__), "../..")
os.chdir(root_path)
import ray
from trade.data.watch_kline_data import WatchDataCenter


if __name__ == "__main__":

    watcher = WatchDataCenter.remote([["BTC/USDT", "1m"], ["ETH/USDT", "1m"]])
    watcher.start.remote()
    ray.get(watcher.join.remote())
